package com.cy.tempflinkcdc.service;


import com.cy.tempflinkcdc.entity.MigrationTable;

import java.util.List;

/**
 * @author: Zzz
 * @date: 2024/3/25 11:22
 * @description:
 */
public interface IncrementSyncService {

    void generatorQueues(String exchangeName, List<MigrationTable> migrationTables);

}
